/**
 * mysql数据库模块
 */
const mysql = require('mysql'); // mysql模块
const jdbcConfig = require('config/jdbc-config'); // 数据库配置
const pool = mysql.createPool(jdbcConfig); // 数据库连接池

const query = async (sql, parms, callback) => {
  // 从数据库连接池获取连接
  pool.getConnection((err, connection) => {
    if (err) {
      callback(err, null, null);
    } else {
      // console.log('查询数据···');
      // console.log(sql);
      // console.log(parms);
      // 执行sql
      connection.query(sql, parms, (error, result, fields) =>{
        connection.release(); // 将连接归还到连接池
        if(error){
          callback(error, null, null);
        }
        callback(error, result, fields);
      });
    }
  });
};

module.exports = query;
